package kevin.bigdata.spark.rdd.builder

import org.apache.spark.{SparkConf, SparkContext}

/**
 * @author: kevin  
 * @date: 11:37 2021/4/30
 */
object RDD_Memory_Par1 {
  def main(args: Array[String]): Unit = {
    //TODO 准备环境
    val sparkConf = new SparkConf().setMaster("local[*]").setAppName("RDD")
      .set("spark.testing.memory","2147480000")
    val sc = new SparkContext(sparkConf)

    //TODO 创建RDD

    // 【1,2】，【3,4】
    //val rdd =sc.makeRDD(List(1,2,3,4), 2)
    // 【1】，【2】，【3,4】
    //val rdd = sc.makeRDD(List(1,2,3,4), 3)
    val rdd = sc.makeRDD(List(1,2,3,4),3)
    rdd.saveAsTextFile("output")

    //TODO 关闭环境
    sc.stop()
  }
}
